import operate from '@dfeidao/atom-nodejs/db/operate';
import { IncomingHttpHeaders } from 'http';
import { productid, systemid } from '../../atom/config';

// 这里是删除
interface Message {
	filter: {
		staff_no: string[]
	};
}
export default async function atom(message: Message, action_id: string, session_id: string, headers: IncomingHttpHeaders) {
	const op=operate(action_id, session_id, systemid);
	 // 删除数据
	op.del('department_staff', { productid,staff_no:{$in:message.filter.staff_no}});
	const res = await op.exec();
	return res;
}
